package mq

import (
	"charging_pile/devices/internal/svc"

	"github.com/zeromicro/go-zero/core/threading"
)

func BatchHand(SvcCtx *svc.ServiceContext) {
	threading.NewWorkerGroup(func() {
		beachHand03(SvcCtx)
	}, 1).Start()

	threading.NewWorkerGroup(func() {
		beachHand08(SvcCtx)
	}, 1).Start()

	threading.NewWorkerGroup(func() {
		beachHand09(SvcCtx)
	}, 1).Start()

	threading.NewWorkerGroup(func() {
		beachHand0A(SvcCtx)
	}, 1).Start()

	threading.NewWorkerGroup(func() {
		beachHand0C(SvcCtx)
	}, 1).Start()
}
